package com.kc.gb.device.plugins.camera.service;

import com.kc.gb.device.plugins.camera.listener.support.CameraPublishEvent;
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.client.producer.DefaultMQProducer;


public interface CameraMQService {

    DefaultMQProducer getMqProducer();

    void sendFeedBackMessage(CameraPublishEvent command) throws Exception;

    DefaultMQProducer createCommandProducer() throws Exception;
}
